package main

import (
	"github.com/astaxie/beego/logs"
	"logagent/kafka"
	"logagent/tailf"
)

func runserver() (err error) {
	for  {
		msg := tailf.GetOneLine()
		err = sendToKafka(msg)
		if err != nil {
			logs.Warn("send to kafka failed,err:",err)
		}
	}
	return
}

func sendToKafka(msg *tailf.TextMsg) (err error) {
	//fmt.Println("read msg:%v",msg)
	err = kafka.SendToKafka(msg.Msg,msg.Topic)
	return
}